package com.weng.bigdata.core.mq.config;

/**
 * MQ 消费组常量
 *
 * @author wengzhonghui
 * @date: 2021-06-25 17:15:52
 */
public class MqConsumerGroupConstants {


    public static final String WEB_SOCKET_GROUP = "web_socket";

    public static final String DATA_COLLECT_GROUP = "data_collect_group";

    public static final String SCHEDULE_CENTER_GROUP = "schedule_center_group";


}